package com.bossien.flink.mapper;

import com.bossien.flink.annatation.BMapper;
import com.bossien.flink.annatation.BSelect;
import com.bossien.flink.interfaces.IMapper;
import org.apache.flink.table.api.Table;

@BMapper
public interface ExamMapper extends IMapper{

     @BSelect("select UserId,SUM(Score) as score from ExamQuestionAnswer GROUP BY UserId")
    // @BSelect("select * from ExamQuestionAnswer")
     Table selectListBySql(Table table);

     Table selectListByTable(Table table);

   }
